-
Notifications
You must be signed in to change notification settings - Fork 841
Expose projection hints in parquet queryable #7152
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
Conversation
05f8242 to
9c6dc46
Compare
|
LGTM, can you check the lint CI? |
|
@SungJin1212 I am waiting for prometheus-community/parquet-common#128 to be merged first. The current projection hints implementation will fail for the default case where the query cannot use projection pushdown |
5b2e6a0 to
e25a78e
Compare
|
LGTM, can you add a changelog? |
SungJin1212
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks
68d3a4d to
efd096d
Compare
Signed-off-by: yeya24 <benye@amazon.com>
efd096d to
4552f4a
Compare
alanprot
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM with a small question.
| sortSeries = true | ||
| } | ||
|
|
||
| queryIngesters := q.queryIngestersWithin == 0 || maxt >= util.TimeToMillis(time.Now().Add(-q.queryIngestersWithin).Add(-q.projectionHintsIngesterBuffer)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This maxt is the original maxt or is the maxt already changed to not contain the timestamp for data in the ingesters?
| blocksStoreQuerier storage.Querier | ||
|
|
||
| // If set, the querier manipulates the max time to not be greater than | ||
| // "now - queryStoreAfter" so that most recent blocks are not queried. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this is what worried about.. that the maxT is already manipulated so we do not see that the query was going to ingesters?
What this PR does:
This PR supports projection pushdown in Parquet Queryable. New config is added to honor projection hints.
Projection pushdown is only enabled if:
Which issue(s) this PR fixes:
Fixes #
Checklist
CHANGELOG.mdupdated - the order of entries should be[CHANGE],[FEATURE],[ENHANCEMENT],[BUGFIX]